FlinkSQL实践记录4 -- 实时更新的维表如何join
1. 背景 对于实时更新的维表，以什么组件来处理作为FlinkSQL的source维表？HBase?Kafka?或mysql？哪一种方案能得到正确结果？ 且需要考虑到事实表和维表关联的时候，是否需要 ...
花费 7 ms
FlinkSQL实践记录2
1. 背景 昨天《FlinkSQL实践记录1》对FlinkSql做了简单的使用insert into .. select ..，今天对聚合运算做一些实践。 2. 代码实践 摘自官网 2 ...
FlinkSQL - Table API Connector 之 Upsert Kafka
1. 简介 The Upsert Kafka connector allows for reading data from and writing data into Kafka topics in ...
FlinkCDC - mysql
1. 背景 FlinkSQL双流关联时，mysql流未能捕捉到Mysql表更新，所以尝试使用FlinkCDC解决此问题。 2022-3-31 21:31:39 语法使用不当导致的未能捕捉，修 ...